package com.caipos.actor.api;


import com.caipos.actor.common.msg.KbMsg;

import java.util.concurrent.ExecutionException;

public interface KbNode {

    void init(KbContext ctx, KbNodeConfiguration configuration) throws KbNodeException;

    void onMsg(KbContext ctx, KbMsg msg) throws ExecutionException, InterruptedException, KbNodeException;

    default void destroy() {
    }

}
